package com.hzz.task;

import com.hzz.framework.scheduling.JobsSchedulingConfigurer;
import com.hzz.service.dsync.ErReportTaskDSync;
import com.hzz.service.dsync.EyBaseTaskDSync;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class EyBaseStartupRunner implements CommandLineRunner {

    @Autowired
    DSyncTask dSyncTask;
    @Autowired
    EyBaseTaskDSync eyBaseTaskDSync;
    @Autowired
    ErReportTaskDSync erReportTaskDSync;
    @Autowired
    DSyncTask.TaskRecordDSyncScheduleTask taskRecordDSyncScheduleTask;
    @Autowired
    DSyncTask.TaskEventDSyncScheduleTask taskEventDSyncScheduleTask;
    @Autowired
    DSyncTask.DsyncEyBaseTaskDSyncScheduleTask dsyncEyBaseTaskDSyncScheduleTask;
    @Autowired
    DSyncTask.DsyncEyBaseImportScheduleTask dsyncEyBaseImportScheduleTask;
    @Autowired
    DSyncTask.DsyncEyBaseTccDSyncScheduleTask dsyncEyBaseTccDSyncScheduleTask;
    @Autowired
    DSyncTask.DsyncErReportTccDSyncScheduleTask dsyncErReportTccDSyncScheduleTask;
    @Autowired
    DSyncTask.DsyncErReportTaskDSyncScheduleTask dsyncErReportTaskDSyncScheduleTask;

    @Autowired
    JobsSchedulingConfigurer jobsSchedulingConfigurer;

    @Override
    public void run(String... args) throws Exception {
        jobsSchedulingConfigurer.add(taskRecordDSyncScheduleTask);
        jobsSchedulingConfigurer.add(taskEventDSyncScheduleTask);
        jobsSchedulingConfigurer.add(dsyncEyBaseTaskDSyncScheduleTask);
        jobsSchedulingConfigurer.add(dsyncEyBaseImportScheduleTask);
        jobsSchedulingConfigurer.add(dsyncEyBaseTccDSyncScheduleTask);
        jobsSchedulingConfigurer.add(dsyncErReportTccDSyncScheduleTask);
        jobsSchedulingConfigurer.add(dsyncErReportTaskDSyncScheduleTask);
        // 启动同步
        // dSyncTask.dsyncEyBaseTaskDSync();
        // dSyncTask.dsyncEyBaseImport();
//        dSyncTask.TaskRecordDSync();
//        dSyncTask.TaskEventDSync();
//        // 渠道
//        eyBaseTaskDSync.dsyncEyBaseRetrieveChn();
//        // 河段和河长关系
//        eyBaseTaskDSync.dsyncEyBaseRetrieveGmHydl();
//        // 河段和河长关系
//        eyBaseTaskDSync.dsyncEyBaseRetrieveChnGm();
//        // 水库-库片
//        eyBaseTaskDSync.dsyncEyBaseReservoirs();
//        erReportTaskDSync.xbOnePage();
        // 拉取_ER_旬报1
//        erReportTaskDSync.xbOnePage();
        // 拉取_ER_旬报2
//        erReportTaskDSync.xbTwoPage();
//        // 拉取_ER_旬报3
//        erReportTaskDSync.xbThreePage();
//        // 拉取_ER_月小结报
//        erReportTaskDSync.monthSummaryPage();
//        // 拉取_ER_工作简报
//        erReportTaskDSync.briefPage();
//        // 拉取_ER_双月报
//        erReportTaskDSync.xdOnePage();
//        // 拉取_ER_年报
//        erReportTaskDSync.xyOnePage();
    }
}
